package org.schat;

/**
 * @Description 消息群发
 * @Author lsh
 **/
public class SendMsgToAllRunnable implements Runnable{

	@Override
	public void run() {
		
		MessageDomain msg=null;
		try {
			while((msg=IMServer.msgQue.take())!=null) {
				IMServer.sendAllClient(msg);
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		
	}
	


}
